//package com.core.system.config.transaction;
//
//import com.core.system.dao.TransactionLogMapper;
//import com.pojo.build.TransactionLogEntity;
//import com.rocketmq.transaction.service.TransactionService;
//import com.utility.util.IdCreateBy;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Service;
//import org.springframework.transaction.annotation.Transactional;
//
///**
// * @author: hw
// * @date: 2021/1/18 15:55
// */
//@Service
//@Slf4j
//public class TransactionServiceImpl extends TransactionCallBackImpl implements TransactionService {
//
//
//    @Autowired private TransactionLogMapper transactionLogMapper;
//
//    /**
//     *  发送事务消息 实现类
//     * @param message  json 消息体
//     * @return
//     */
//    @Transactional(rollbackFor = Exception.class)
//    @Override
//    public int sendTransaction(String message) {
////        systemTransactionMapper.insert(systemTransactionDto);
//        TransactionLogEntity transactionLogEntity = new TransactionLogEntity();
////        return transactionLogMapper.insert(transactionLogEntity);
//        return 1;
//    }
//
//    /**
//     *  根据事务Id查询 事务是否已完成
//     * @param transactionId 事务id
//     * @return
//     */
//    @Override
//    public boolean transactionCallBack(String transactionId){
//        return super.getTransactionCallBack(transactionId);
//    }
//}
